package com.kancy.streamplus.channel;

import org.springframework.messaging.Message;

/**
 * @author kancy
 * @date 2019/12/19 21:58
 **/
public interface PollingMessageHandler<T extends PollingMessage> {
    /**
     * 处理消息
     * @param message
     * @throws Exception
     */
    void handleMessage(Message<T> message) throws Exception;
}
